package com.teradata.multithread.dsrptor;

/**
 * @author: lyndon
 * @version: 1.0
 * @date: 2019/2/18
 */
public class Main {

    public static void main(String[] args) {

        DisruptorManager manager = new DisruptorManager(new SftpGetFileHandler(), new InsertDbHandler());

        final Message message = new Message();
        message.setId("1111");
        message.setName("huzy");

        manager.work(message);

        manager.destroy();
    }

}
